package com.avoid.easymqtt.mqtt;

import io.netty.channel.ChannelHandlerContext;
import io.netty.handler.codec.mqtt.MqttMessage;

/**
 * 描述
 *
 * @author avoid@fiture.com
 * @date 2022/5/6
 * @motto Life is so short,do something to make yourself happy,such as coding
 */
public interface MqttRequestProcessor {

    MqttMessage processRequest(ChannelHandlerContext ctx, MqttMessage msg)
        throws Exception;

    boolean rejectRequest();

}
